<?php
/**
 * tis-tis 数据库操作实例共用类
 *
 * @copyright (c)2010 昆明力行软件  保留所有权利。
 * @link http://www.tis-tis.com
 * @Author: XiangJie
 * @version: 1.0.0
 */

/**
 * 数据库操作的封装。
 */
require_once 'common.php';
class MySql {
	/**
	 * 查询次数
	 * @var int
	 */
	private $query_Count_Num = 0;
	/**
	 * 内部数据连接对象
	 * @var resourse
	 */
	private $connection;
	/**
	 * 内部数据结果
	 * @var resourse
	 */
	private $result;
	/**
	 * 内部实例对象
	 * @var object MySql
	 */
	private static $EINSTANCE = null;

	/**
	 * 构造函数
	 *
	 */
	private function __construct() {
		if (!function_exists('mysql_connect')) {
			$links[0] = '服务器PHP不支持MySql数据库';
			$links[1] = "<a href='./'>点击返回</a>";
			tisMessage($links);
		}
		if (!$this->connection = @mysql_connect(DB_HOST, DB_USER, DB_PASSWD)) {
			$links[0] = '连接数据库失败,可能是数据库用户名或密码错误';
			$links[1] = "<a href='./'>点击返回</a>";
			tisMessage($links);
		}
		if ($this->getMysqlVersion() > '4.1') {
			mysql_query("SET NAMES 'utf8'");
		}
		/*如果数据库不存在创建数据库*/
		@mysql_query("create database if not exists `".DB_NAME."`;", $this->connection);
		@mysql_select_db(DB_NAME, $this->connection);
	}

	/**
	 * 静态方法，返回数据库连接实例
	 *
	 * @return MySql
	 */
	public static function getInstance() {
		if (self::$EINSTANCE == null) {
			self::$EINSTANCE = new MySql();
		}
		return self::$EINSTANCE;
	}

	/**
	 * 关闭数据库连接
	 *
	 * @return boolean
	 */
	function close() {
		return mysql_close($this->connection);
	}

	/**
	 * 发送查询语句
	 *
	 * @param string $sql
	 * @return boolean
	 */
	function query($sql) {
		$this->result = @mysql_query($sql, $this->connection);
		$this->query_Count_Num++;
		if (!$this->result) {
			$links[0] = "SQL语句执行错误：$sql <br />" . $this->geterror();
			$links[1] = "<a href='./'>点击返回</a>";
			tisMessage($links);
		}else {
			return $this->result;
		}
	}

	function getAll($sql)
	{
		$res = $this->query($sql);
		if ($res !== false)
		{
			$arr = array();
			while ($row = mysql_fetch_assoc($res))
			{
				$arr[] = $row;
			}

			return $arr;
		}
		else
		{
			return false;
		}
	}

	function getRow($sql, $limited = false, $limited_num = 1)
	{
		if ($limited == true)
		{
			$sql = trim($sql . ' LIMIT '.$limited_num);
		}

		$res = $this->query($sql);
		if ($res !== false)
		{
			return mysql_fetch_assoc($res);
		}
		else
		{
			return false;
		}
	}

	function getOne($sql, $limited = false)
	{
		if ($limited == true)
		{
			$sql = trim($sql . ' LIMIT 1');
		}

		$res = $this->query($sql);
		if ($res !== false)
		{
			$row = mysql_fetch_row($res);

			if ($row !== false)
			{
				return $row[0];
			}
			else
			{
				return '';
			}
		}
		else
		{
			return false;
		}
	}

	/**
	 *  返回数据库中的表名
	 *  @param string $table_name 要操作的表名
	 *  @return string 对应数据库中的表名
	 */
	function table($table_name) {
		return DB_PREFIX.$table_name;
	}

	/**
	 * 从结果集中取得一行作为关联数组/数字索引数组
	 *
	 * @param resource $query
	 * @return array
	 */
	function fetch_array($query) {
		return mysql_fetch_array($query);
	}

	function once_fetch_array($sql) {
		$this->result = $this->query($sql);
		return $this->fetch_array($this->result);
	}

	/**
	 * 从结果集中取得一行作为数字索引数组
	 *
	 * @param resource $query
	 * @return integer
	 */
	function fetch_row($query) {
		return mysql_fetch_row($query);
	}

	/**
	 * 取得行的数目
	 *
	 * @param resource $query
	 * @return integer
	 */
	function num_rows($query) {
		return mysql_num_rows($query);
	}

	/**
	 * 取得结果集中字段的数目
	 *
	 * @param resource $query
	 * @return integer
	 */
	function num_fields($query) {
		return mysql_num_fields($query);
	}
	/**
	 * 取得上一步 INSERT 操作产生的 ID
	 *
	 * @return integer
	 */
	function insert_id() {
		return mysql_insert_id($this->connection);
	}

	/**
	 * 获取mysql错误
	 *
	 * @return unknown
	 */
	function geterror() {
		return mysql_error();
	}

	/**
	 * Get number of affected rows in previous MySQL operation
	 *
	 * @return int
	 */
	function affected_rows() {
		return mysql_affected_rows();
	}

	/**
	 * 取得数据库版本信息
	 *
	 * @return string
	 */
	function getMysqlVersion() {
		return mysql_get_server_info();
	}

	/**
	 * 取得数据库查询次数
	 *
	 * @return string
	 */
	function getQueryCount() {
		return $this->query_Count_Num;
	}
}
